import asyncio
from rustplus_.rustplus import RustSocket

async def on_success(*args, **kwargs):
    print(f"Success: Ip is {kwargs['ip']} and port is {kwargs['port']}")


def on_failure(*args, **kwargs):
    print(f"Error: Ip is {kwargs['ip']} and port is {kwargs['port']}")

async def main():
    socket = RustSocket("ip", "port", steamid, player_token)
    kwargs = {"ip": "ip", "port": port}
    await socket.connect(on_failure=on_failure, on_success=on_success, on_success_kwargs=kwargs, on_failure_kwargs=kwargs)
    print(f"It is {(await socket.get_time()).time}")

    await socket.disconnect()

asyncio.run(main())